package cn.jly.boot.kafka.service;

import org.apache.kafka.clients.consumer.ConsumerRecord;

/**
 * @PackageName cn.jly.boot.kafka.service
 * @ClassName KafkaConsumer
 * @Description kafka消费者
 * @Author 姬岚洋
 * @Date 2021/1/10 下午 9:26
 */
public interface KafkaConsumer {
    void onMessage(ConsumerRecord<?, ?> record);
}
